c965c5946911063352804e591955e8d1927aed6e,src/test/java/com/continuuity/data/operation/ttqueue/TestHBaseNewTTQueue.java,TestHBaseNewTTQueue,testSingleStatefulConsumerWithHashPartitioning,#,106
Before Change
// enqueue some entries
for(int i=0; i<numQueueEntries; i++) {
QueueEntry queueEntry=new QueueEntryImpl(Bytes.toBytes("value"+i%numConsumers));
queueEntry.addPartitioningKey(HASH_KEY, i);
assertTrue(queue.enqueue(queueEntry, dirtyVersion).isSuccess());
}
// dequeue it with HASH partitioner
After Change
// enqueue some more entries
for(int i=numQueueEntries; i<numQueueEntries*2; i++) {
QueueEntry queueEntry=new QueueEntryImpl(Bytes.toBytes(i+1));
queueEntry.addPartitioningKey(HASH_KEY, i+1);
assertTrue(queue.enqueue(queueEntry, dirtyVersion).isSuccess());
}
// dequeue and verify